package rabbitMQ.client;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

public class Send {
	private  final  static String QUEUE_NAME ="hello" ;
	public static void  main (String [] args) {
		ConnectionFactory factory = new ConnectionFactory();
		factory.setHost("localhost");
	Connection connection = null;
	try {
		connection = factory.newConnection();
		Channel channel = connection.createChannel();
		channel.queueDeclare(QUEUE_NAME,false,false,false,null);
		String message ="hello world";
		channel.basicPublish("",QUEUE_NAME,null,message.getBytes());
		System.out.println("[x] Sent'"+ message +"'");
	} catch (IOException | TimeoutException e) {
		e.printStackTrace();
	}
	  
	}
}
